32173c04503afc6a7efd7aa2543e41a83d4bcd59,jrpc-transport-mina/src/main/java/com/dinstone/jrpc/transport/mina/MinaConnector.java,MinaConnector,initConnector,#InetSocketAddress#TransportConfig#,90

Before Change


        encoder.setMaxObjectSize(config.getMaxSize());
        decoder.setMaxObjectSize(config.getMaxSize());
        // add filter
        chainBuilder.addLast("codec", new ProtocolCodecFilter(new ProtocolCodecFactory() {

            public ProtocolEncoder getEncoder(IoSession session) throws Exception {
                return encoder;
            }

            public ProtocolDecoder getDecoder(IoSession session) throws Exception {
                return decoder;
            }
        }));

        // add keep alive filter
        ActiveKeepAliveMessageFactory messageFactory = new ActiveKeepAliveMessageFactory(config.getSerializeType());

After Change


        encoder.setMaxObjectSize(config.getMaxSize());
        decoder.setMaxObjectSize(config.getMaxSize());
        // add filter
        chainBuilder.addLast("codec", new ProtocolCodecFilter(encoder, decoder));

        // add keep alive filter
        ActiveKeepAliveMessageFactory messageFactory = new ActiveKeepAliveMessageFactory(config.getSerializeType());